package com.dja.nzw.mq.kafka.config;

import org.apache.kafka.common.serialization.ByteArrayDeserializer;
import org.apache.kafka.common.serialization.StringDeserializer;

import java.util.Properties;

/**
 * Created by shuyun on 2017/7/15.
 */
public class KafkaConsumerProperties {
    /** 服务器地址信息 */
    private String zkList;
    /** key序列化类 */
    private String keyClass = StringDeserializer.class.getName();
    /** value序列化类 */
    private String valueClass = ByteArrayDeserializer.class.getName();

    /** 是否自动提交 */
    private boolean autoCommit;
    /** 组名 */
    private String groupId;

    /** 其它额外的配置 */
    private Properties extras;
}
